--[[ 编码: WMS-17-12 名称: 计划盘点容器-Create_Count_CG_Detail 作者：HAN 日期：2025-1-29 级别：固定 (说明本段代码在项目中不太会变化) 函数： CreateCountCGDetail 功能: -- 外部触发的事件，输入paramter = { reject_emptybox "count_type":1/2, "count_order_no":"盘点单号", "count_method":1/2 盘点方法, station, diff_hand_method } -- 根据 CG_Detail 生成 Count_CG_Detail -- 先清空 Count_CG_Detail -- 成功后需要对容器加 盘点锁 更改记录: V2.0 HAN 2025-2-9 相同货品的CG_Detail 数量合并 V3.0 HAN 2025-2-13 新增容器盘点类型 V4.0 HAN 2025-2-15 空料箱是否出库盘点判断 --]] wms_base = require( "wms_base" ) function CreateCountCGDetail ( strLuaDEID ) local nRet, strRetInfo local paramter -- step1: 获取输入参数 nRet, paramter = m3.GetSysDataJson( strLuaDEID ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "获取输入参数失败! "..paramter ) end local count_type = lua.Get_NumAttrValue( paramter.count_type ) if ( count_type == 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "输入参数中必须要有 count_type ! " ) end local count_order_no = lua.Get_StrAttrValue( paramter.count_order_no ) if ( count_order_no == "" ) then lua.Error( strLuaDEID, debug.getinfo(1), "输入参数中必须要有 count_order_no ! " ) end local count_method = lua.Get_NumAttrValue( paramter.count_method ) if ( count_method <= 0 or count_method > 2 ) then lua.Error( strLuaDEID, debug.getinfo(1), "输入参数中 count_method 不合法! " ) end local station = lua.Get_StrAttrValue( paramter.station ) -- 盘点站台 local diff_hand_method = lua.Get_NumAttrValue( paramter.diff_hand_method ) local count_container nRet, count_container = m3.GetSysCurEditDataObj( strLuaDEID, "CP_Count_Container" ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "获取当前编辑属性失败! "..count_container ) end local strClsID, strObjID nRet, strClsID, strObjID = mobox.getCurEditDataObjID( strLuaDEID ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "getCurEditDataObjID失败! " ) end count_container.id = strObjID -- step2: 先删除【Count_CG_Detail】 local strCondition = "S_COUNT_NO = '"..count_container.count_no.."' AND S_CNTR_CODE = '"..count_container.cntr_code.."'" nRet, strRetInfo = mobox.dbdeleteData(strLuaDEID, "Count_CG_Detail", strCondition) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "删除【Count_CG_Detail】失败!"..strRetInfo) end -- step3: 根据盘点类型生成盘点货品明细 local strOrder = '' local count_cg_detail -- 根据盘点类型不同设定不同查询条件 if ( count_type == 1 ) then -- 货品盘点 -- 获取容器需要盘点什么货品，["A","B"] if ( count_container.good_codes == nil or count_container.good_codes == '') then lua.Debug( strLuaDEID, debug.getinfo(1),"count_container", count_container ) lua.Error( strLuaDEID, debug.getinfo(1), "货品查询条件为空! " ) end local str_good_codes = lua.strArray2string(json.decode( count_container.good_codes )) if ( str_good_codes ~= nil and str_good_codes ~= '' ) then -- str_good_codes = lua.trim_str_head_end( str_good_codes ) -- 从CG_Detail获取货品 strCondition = "S_ITEM_CODE IN ("..str_good_codes..") AND S_CNTR_CODE = '"..count_container.cntr_code.."'" else lua.Debug( strLuaDEID, debug.getinfo(1),"count_container", count_container ) lua.Error( strLuaDEID, debug.getinfo(1), "货品查询条件为空! " ) end elseif ( count_type == 2 ) then -- 货位盘点 strCondition = "S_CNTR_CODE = '"..count_container.cntr_code.."'" -- V3.0 elseif ( count_type == 3 ) then -- 容器盘点 strCondition = "S_CNTR_CODE = '"..count_container.cntr_code.."'" else lua.Error( strLuaDEID, debug.getinfo(1), "输入参数count_type值非法! count_type = "..count_type ) end local data_objs, i, n nRet, data_objs = m3.QueryDataObject(strLuaDEID, "CG_Detail", strCondition, strOrder ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "QueryDataObject失败!"..data_objs) end -- V2.0 local cg_detail_list = {} local find if ( data_objs ~= '') then for i = 1, #data_objs do object_attr = m3.KeyValueAttrsToObjAttr(data_objs[i].attrs) -- V2.0 判断cg_detail_list find = false for n = 1, #cg_detail_list do if ( cg_detail_list[n].item_code == object_attr.S_ITEM_CODE ) then cg_detail_list[n].qty = cg_detail_list[n].qty + lua.StrToNumber( object_attr.F_QTY ) cg_detail_list[n].cg_detail_id = "" -- 说明是有多条记录合并的，因此需要批分 find = true break end end if ( find == false ) then count_cg_detail = m3.AllocObject(strLuaDEID,"Count_CG_Detail") count_cg_detail.cg_detail_id = data_objs[i].id count_cg_detail.cc_no = count_container.cc_no count_cg_detail.count_no = count_order_no count_cg_detail.station = station count_cg_detail.cntr_code = object_attr.S_CNTR_CODE count_cg_detail.cell_no = object_attr.S_CELL_NO count_cg_detail.serial_no = object_attr.S_SERIAL_NO count_cg_detail.item_code = object_attr.S_ITEM_CODE count_cg_detail.item_name = object_attr.S_ITEM_NAME count_cg_detail.batch_no = object_attr.S_BATCH_NO count_cg_detail.item_spec = object_attr.S_ITEM_SPEC count_cg_detail.item_state = object_attr.N_ITEM_STATE count_cg_detail.end_user = object_attr.S_END_USER count_cg_detail.owner = object_attr.S_OWNER count_cg_detail.supplier = object_attr.S_SUPPLIER_NO count_cg_detail.erp_wh_code = object_attr.S_ERP_WH_CODE count_cg_detail.ext_attr1 = object_attr.S_EXT_ATTR1 count_cg_detail.ext_attr2 = object_attr.S_EXT_ATTR2 count_cg_detail.ext_attr3 = object_attr.S_EXT_ATTR3 count_cg_detail.ext_attr4 = object_attr.S_EXT_ATTR4 count_cg_detail.ext_attr5 = object_attr.S_EXT_ATTR5 count_cg_detail.qty = lua.StrToNumber( object_attr.F_QTY ) count_cg_detail.uom = object_attr.S_UOM table.insert( cg_detail_list, count_cg_detail ) end end end --V4.0 local nCount = #cg_detail_list if ( nCount == 0 and paramter.reject_emptybox ) then -- 空料箱不需要出库盘点 -- 更新【计划盘点容器】中的属性 strCondition = "S_ID = '"..strObjID.."'" -- 设置 状态=4/已回库（完成） local strSetSQL = "N_B_STATE = 4" nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "CP_Count_Container", strCondition, strSetSQL) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "设置【计划盘点容器】信息失败!"..strRetInfo ) end -- 增加一个后台进程对盘点单进行处理，检查盘点单是否可以完成 local add_wfp = { wfp_type = 1, cls = "CP_Count_Container", obj_id = strObjID, obj_name = "盘点容器流水号'"..count_container.cc_no.."'-->盘点完成后处理", trigger_event = "盘点完成后处理" } nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "AddSysWFP失败!"..strRetInfo ) end return end for n = 1, #cg_detail_list do nRet, count_cg_detail = m3.CreateDataObj( strLuaDEID, cg_detail_list[n] ) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "创建【Count_CG_Detail】失败!"..count_cg_detail) end end -- step4: 更新【计划盘点容器】中的属性 strCondition = "S_ID = '"..strObjID.."'" -- 设置 盘点单号 及 状态=1/已锁定 local strSetSQL = "S_COUNT_NO = '"..count_order_no.."', N_B_STATE = 1, N_COUNT_METHOD = "..count_method..", S_STATION_NO = '"..station.."', N_DIFF_HAND_METHOD = "..diff_hand_method nRet, strRetInfo = mobox.updateDataAttrByCondition(strLuaDEID, "CP_Count_Container", strCondition, strSetSQL) if (nRet ~= 0) then lua.Error( strLuaDEID, debug.getinfo(1), "设置【计划盘点容器】信息失败!"..strRetInfo ) end -- step5: 如果【计划盘点容器】的盘点方法=2 （自动出库到站点）就需要在后台创建作业进【盘点出库】作业 if ( count_method == 2 ) then -- 增加一个后台进程进行入库单完工回报 local add_wfp = { wfp_type = 1, -- 触发数据对象事件（指定数据对象标识） cls = "CP_Count_Container", obj_id = count_container.id, obj_name = "Container No '"..count_container.cntr_code.."'-->Create stocktaking outbound operation", trigger_event = "CreateStocktakingOutOperation" } nRet, strRetInfo = m3.AddSysWFP( strLuaDEID, add_wfp ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "AddSysWFP失败!"..strRetInfo ) end end -- step6: 给容器加盘点锁 4 -- 盘点锁 nRet, strRetInfo = wms.wms_LockCntr( count_container.cntr_code, 4, count_order_no ) if ( nRet ~= 0 ) then lua.Error( strLuaDEID, debug.getinfo(1), "给容器'"..operation_obj.cntr_code.."'加盘点锁失败!") end wms.wms_CommitCntrLockTrans( count_order_no ) end